package com.pangyangyang.elasticsearch.plugin.util;

/**
 * Created by yangwang on 2015/1/15.
 */
public class MessageRiverConstants {

    public static final String COMMON_SPLITTER = "#";
    public static final String COMMON_DOT = ".";

    public static final String SETTING_KEY_NAMESPACE_HANDLER = "handler";
    public static final String SETTING_KEY_NAMESPACE_COLLECTOR = "collector";

    public static final String SETTING_KEY_COMMON_HOST = "host";
    public static final String SETTING_KEY_COMMON_PORT = "port";
    public static final String SETTING_KEY_COMMON_TYPE = "type";
    public static final String SETTING_KEY_COMMON_CLASS = "clazz";
    public static final String SETTING_KEY_COMMON_USERNAME = "username";
    public static final String SETTING_KEY_COMMON_PASSWORD = "password";
    public static final String SETTING_KEY_COMMON_DESTINATION = "destination";
    public static final String SETTING_KEY_COMMON_TIMEOUT = "timeout";
    public static final String SETTING_KEY_COMMON_INDEX = "index";

    public static final String SETTING_KEY_CANAL_BLOCKED = "blocked";
    public static final String SETTING_KEY_CANAL_BATCH_SIZE = "batch_size";
    public static final String SETTING_KEY_CANAL_SLEEP_SEC = "sleep";

    public static final String SETTING_KEY_HANDLER_JDBC_ACTION = "action";

}
